package org.zbus.examples.proxy;

import org.zbus.broker.Broker;
import org.zbus.broker.ZbusBroker;
import org.zbus.mq.Producer;
import org.zbus.net.http.Message;

public class MqExample {
	public static void main(String[] args) throws Exception {
		Broker broker = new ZbusBroker("127.0.0.1:17777");

		Producer producer = new Producer(broker, "/MyMQ");
		producer.createMQ();
		
//		producer.removeMQ();

		broker.close();
	}
}
